//package com.bsoft.MQ.consumer;
//
//import org.apache.rocketmq.spring.annotation.ConsumeMode;
//import org.apache.rocketmq.spring.annotation.MessageModel;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.stereotype.Service;
//
////@Service
////@RocketMQMessageListener(topic = "generateInvoice", consumerGroup = "consumer-group", selectorExpression = "*",
////        consumeMode = ConsumeMode.CONCURRENTLY, messageModel = MessageModel.CLUSTERING)
//public class ConsumerService implements RocketMQListener<String> {
//    @Override
//    public void onMessage(String s) {
//        System.out.printf("收到消息: %s\n", s);
//    }
//}
